//package com.boot.config;
//
//import com.ctrip.framework.apollo.model.ConfigChange;
//import com.ctrip.framework.apollo.model.ConfigChangeEvent;
//import org.springframework.beans.BeansException;
//import org.springframework.cloud.context.environment.EnvironmentChangeEvent;
//import org.springframework.context.ApplicationContext;
//import org.springframework.context.ApplicationContextAware;
//import org.springframework.stereotype.Component;
//
//@Component
//public class ApolloConfigChanged implements ApplicationContextAware {
//
//    private ApplicationContext applicationContext;
//
//    /***
//     * 指定需要监听的namespace
//     * @param changeEvent
//     */
//    //@ApolloConfigChangeListener(value = {"spring-kafka"})
//    public void someChangeHandler(ConfigChangeEvent changeEvent) {
//        for (String key : changeEvent.changedKeys()) {
//            ConfigChange change = changeEvent.getChange(key);
//            System.out.println("Found change - {}" + change.toString());
//        }
//
//        // 更新相应的bean的属性值，主要是存在@ConfigurationProperties注解的bean
//        this.applicationContext.publishEvent(new EnvironmentChangeEvent(changeEvent.changedKeys()));
//    }
//
//    @Override
//    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
//        this.applicationContext = applicationContext;
//    }
//}